#coding=utf-8
#!/usr/bin/python


# cd /d D:\python2.6.6\dev_test 
#     cd /d D:\python26 
#     python.exe D:\py\demo\updb.py

""" 
 

倒入到v2

    
    更新到 v2
    
    查看手机号码是否存在
    
    是否有联系记录
    
    插入并更改销售

先插入 
    用户数据    手机存在 联系记入 就更新   销售 123456
    然后插入    ws_to_v2
    
        

"""
import os, sys, string
import bus_op_com as op_db  #数据操作 


#所有数据
tmp_tab = op_db.tmp_tab();   #对象
#sys.exit()

tmp_tab.init_v2();                 #初始化
tmp_tab.init_ws();                 #初始化


tab_rows = tmp_tab.get_tmp_tab_all();   #所有 ws 客户


in_cut_num = 0  #插入数据
in_real_cut_num = 0 #实际插入

up_cut_num = 0    #更新数据
up_real_cut_num = 0 #实际更新

exist_num = 0      #存在数据

error_num     = 0  # 插入错误数据
exist_record_num = 0 #已经连续过
matter_id_dict  = {} #有问题的数据

#sys.exit()
for tmp_row in tab_rows:
    #break
    print str(tmp_row['id']) + u'=================================='
    #---loop
    #获取 客户资料
    cur_row = tmp_tab.get_cur_by_phone( tmp_tab.get_dictv('手机号',tmp_row) )
    #客户存在
    if not cur_row.has_key('customer_id'):
        print 'inset'
        in_cut_num += 1
        state = tmp_tab.into_v2_cut(tmp_row)
        v2_id = tmp_tab.get_v2_insert_id()
        #插入客户
        if state:
            tmp_state = tmp_tab.into_ws_to_v2(tmp_row['id'],v2_id)
            if tmp_state:
                in_real_cut_num += 1
        else:
            error_num +=    1
            

    else:
        print 'exist'
        exist_num += 1
        #存在 但是没有联系记录
        if not tmp_tab.exist_cur_record(cur_row['customer_id']):
            print 'update'
            up_cut_num += 1
            tmp_tab.into_ws_to_v2(tmp_row['id'],cur_row['customer_id'])
            state = tmp_tab.up_v2_cur(cur_row['customer_id'])
            if state:
                up_real_cut_num += 1    
            else:
                matter_id_dict[tmp_row['id']] = cur_row['customer_id']
                #matter_id_list.append(cur_row['customer_id'])
        else:
            exist_record_num +=    1

        
        
    #end for
print "\n".join(["%i=%i" % (k ,matter_id_dict[k] ) for k in matter_id_dict.keys() ])
print "matter_id_dict length = " , len(matter_id_dict.keys())
print ' len = ' ,len(tab_rows)
print ' in_cut_num=' , in_cut_num,' in_real_cut_num=',in_real_cut_num
print ' exist_num=' , exist_num, ' up_cut_num=' ,up_cut_num ,' up_real_cut_num =' ,up_real_cut_num
print ' exist_record_num='  ,exist_record_num , ' error_num =',error_num
print 'the end'
sys.exit()





